package io.xxx.mario.task.receive;

import io.xxx.mario.task.Task;
import reactor.core.publisher.Flux;

/**
 * 接收者选择器
 */
public interface ReceiverSelector {

    Flux<Receiver> select(Task task);
}
